package com.until;

import com.model.MyUser;
import com.service.MyuserService;
import io.swagger.annotations.Api;
import io.swagger.models.auth.In;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

@Component//组件
@EnableScheduling  //开启定时任务
public class AlarmTask {
    private static final SimpleDateFormat myFormat=new SimpleDateFormat("YYYY-MM-DD HH:mm:ss");
    public static int count=0;

    @Autowired
    private MyuserService myuserService;

//    /*插入：10s一次   有固定频率执行 上一个任务开始后，5s后再开始执行*/
//    @Scheduled(fixedRate = 10000)
//    public void runInsert() throws InterruptedException{
//        MyUser myUser=new MyUser();
//
//        System.out.println("fixRate,当前时间"+myFormat.format(new Date()));
//        System.out.println("Insert");
//
//        int temp=(int)System.currentTimeMillis();
//
////        myUser.setUserid(temp%100);
//        myUser.setLogtime(new Date());
//        myUser.setMethod("插入数据");
//        myUser.setIp("192.168.26."+Integer.toString((temp%255)));
//
//        myuserService.addMyUser(myUser);
//        System.out.println(Thread.currentThread().getName()+"===="+System.currentTimeMillis()/1000);
//        System.out.println("--------------------------------");
//    }
//
//    /*查询全部：插入完成后间隔5s 固定的延迟时间执行，基于上一个任务完成后，延迟5s*/
//    @Scheduled(fixedDelay = 5000)
//    public void runAll() throws InterruptedException{
//        Thread.sleep(5000);
//        MyUser myUser=new MyUser();
//        System.out.println("fixDelay,当前时间"+myFormat.format(new Date()));
//        System.out.println("统计");
//
//        List<MyUser> myUserList=myuserService.getAllMyUsers(myUser);
//        System.out.println("共有"+myUserList.size()+"条记录");
//        for(MyUser temp : myUserList){
//            System.out.println(temp.toString());
//            System.out.println();
//        }
//        System.out.println(Thread.currentThread().getName()+"===="+System.currentTimeMillis()/1000);
//        System.out.println("--------------------------------");
//    }
//
//    /*查询后10条：查询全部完成后间隔5s 固定的延迟时间执行，基于上一个任务完成后，延迟5s*/
//    @Scheduled(initialDelay = 2000,fixedDelay = 5000)
//    public void run3() throws InterruptedException{
//        Thread.sleep(5000);
//        MyUser myUser=new MyUser();
//        System.out.println("fixDelay,当前时间"+myFormat.format(new Date()));
//        System.out.println("查询后10条");
//
//        List<MyUser> myUserList=myuserService.getLast10(myUser);
//        for(MyUser temp : myUserList){
//            System.out.println(temp.toString());
//        }
//        System.out.println("--------------------------------");
//    }
}
